package com.sample.jobs;

import com.swak.annotation.Flux;
import com.swak.annotation.Job;
import com.swak.job.JobFragment;
import com.swak.utils.Fmt;
import com.swak.utils.StringUtils;

/**
 * 定义任务: 固定的调度数量。
 * 
 * @author lifeng
 * @date 2021年2月25日 下午1:28:31
 */
@Flux
@Job(id = "WechatJob", name = "微信刷新任务", executeMethod = "execute")
public class WechatJob2 {

	/**
	 * 执行分片： 可以异步处理
	 * 
	 * @param task
	 */
	public void execute(JobFragment task) {
		Fmt.out.println(StringUtils.format("执行器 %s - 任务 %s, 线程 %s", this.getClass().getName(), task,
				Thread.currentThread().getName()));
	}
}